// package com.tj.pystandard.tjcustomer.rocketmq.service;
//
// import lombok.extern.slf4j.Slf4j;
// import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
// import org.apache.rocketmq.spring.core.RocketMQListener;
// import org.springframework.stereotype.Service;
//
// @Service
// @Slf4j
// @RocketMQMessageListener(consumerGroup = "consumer-group", topic = "ace-msg")
// public class TestRocketCustomer implements RocketMQListener<String> {
//     @Override
//     public void onMessage(String str) {
//         // TODO 业务处理
//         log.info("监听到主题为'ace-msg'的消息：" + str);
//     }
// }
